// 加载数据库模块
var mysql = require('mysql');

// 获取连接对象
var conn = mysql.createConnection({
    host: '127.0.0.1',   //  连接主机
    user: 'root',        //  用户名
    password: 'root',    //  密码
    database: 'php71',   //  数据库

})

// 打开连接
conn.connect();

// 回调函数，输出模块数据
module.exports = {
    wh: '',
    where: function (whs) {
        this.wh = whs;
        return this;
    },

    // 链式操作，单个查询
    select: function (callback) {
        // 如果wh没有值，那么自动查询所有，sql变成所有
        if (this.wh == '') {
            var sql = 'select * from users';
        } else {
            var sql = "select * from users where " + this.wh;
        }
        // 查询执行sql语句
        conn.query(sql, function (err, sql_data) {
            callback(sql_data);
        });
        // 每一次查询都清空掉wh，
        this.wh = '';
    },

    // 修改数据
    updata: function (data, callback) {
        // 如果wh没有值，
        if (this.wh == '') {
            callback(0);
        } else {
            var set = '';
            for (k in data) {
                set += k + "='" + data[k] + "',";
            }
            set=set.slice(0,-1);
            var sql="update users set "+set+" where "+this.wh;
            this.wh='';
        }
        // 查询执行sql语句
        conn.query(sql, function (err, sql_data) {
            callback(sql_data);
        });
    }
};


